var dbserver = require("../server/dbserver")
module.exports = function(io){
  let user = {};//此处显示目前在线的人
  io.on('connection',(socket)=>{
    socket.on('login',(id)=>{//用户登录时发送信息
      socket.name = id;
      user[id] = socket.id
      // console.log(user);
    })

    socket.on('disconnect',()=>{//用户退出
      if(user.hasOwnProperty(socket.name)){
        delete user[socket.name]
      }
    })
    socket.on('msg',(data)=>{
      socket.to(user[data.tid]).emit('msg',data,0);//广播给朋友
      // console.log(data.data)
      if(data.type == 3){
        data.data = JSON.stringify(data.data)
      }
      dbserver.insertMsg(data.uid,data.tid,data.data,data.type);//上传到数据库
      //存放数据库(修改未读信息数)
      socket.emit('msg',data,1);//广播给自己
    })


    //加入群
    socket.on('group',(gid)=>{
      // console.log('群'+gid)
      socket.join(gid)//通过群号创建房间
    });
    //接收群信息
    socket.on('groupmsg',(data)=>{
      // console.log(data)
      socket.to(data.tid).emit('groupmsg',data,0);//广播到群
      if(data.type == 3){
        data.data = JSON.stringify(data.data)
      }
      dbserver.insertGroupMsg(data.tid,data.uid,data.data,data.type);//上传到数据库
      socket.emit('groupmsg',data,1);//广播给自己
    })
  })
}